package com.gitee.xmhzzz.emqx.client.listener;


import com.gitee.xmhzzz.emqx.client.model.message.IMessage;

public interface IMqttListener {

    /**
     * Description: 路由topic
     **/
    String getTopic();

    /**
     * Description: 消费类型 广播、集群模式
     **/
    String getType();

    /**
     * Description: 消息处理
     **/
    void onMessage(IMessage message);
}
